package com.study.service.impl.rocket;

import com.study.service.MessageService;
//import org.apache.rocketmq.spring.core.RocketMQTemplate;
import org.apache.rocketmq.spring.core.RocketMQTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

/**
 * @desc:
 * @author: panxiyi
 * @date: 2023/5/13 12:00 上午
 */
@Service
public class MessageServiceRocketMqImpl implements MessageService {

//    @Autowired
//    private RocketMQTemplate rocketMQTemplate;

    @Override
    public void sendMessage(String id) {
        System.out.println("加入短信发送队列 -- RocketMq 处理 " + id);
        //rocketMQTemplate.convertAndSend("order_id", id);
    }

    @Override
    public String doSendMessage() {
        return null;
    }
}
